package com.zengfa.task.server.application;

import java.util.List;

import com.zengfa.task.api.model.JobDTO;
import com.zengfa.task.api.model.JobNodeDTO;
import com.zengfa.task.server.domain.entity.Job;
import com.zengfa.task.server.domain.entity.JobNode;


public interface JobAppService {

	/**
	 * 获得任务
	 * @param jobId
	 * @return
	 */
	public JobDTO getJob(String jobId);
	
	/**
	 * 停止任务
	 * @param jobId
	 */
	public void stopJob(String jobId);
	
	/**
	 * 停止任务
	 * @param jobId
	 */
	public void stopJob(Job job);
	
	
	/**
	 * 获取任务节点列表
	 * @param bizType
	 * @param bizId
	 * @return
	 */
	public List<JobNode> getJobNodeList(String bizType,String bizId);
	
	/**
	 * 重试任务节点
	 * @param nodeId
	 */
	public JobNodeDTO retryJobNode(String nodeId);
	
}
